from __future__ import absolute_import, unicode_literals
from celery import task
import time
from django.core.mail import send_mail
from mydjango import settings

# 这里不再使用@app.task,而是用@shared_task，是指定可以在其他APP中也可以调用这个任务
@task
def add(x,y):
    print('########## running add #####################')
    return x + y

@task
def minus(x,y):
    time.sleep(30)
    print('########## running minus #####################')
    return x - y


@task
def send_email(useremail,html_message):
    print('发送中……')
    subject = "用户管理员激活"  # 邮件的标题
    message = "你好。"  # 邮件的内容，该内容不会显示html格式的文本，如需要html文本要使用html_message
    from_email = settings.EMAIL_FROM  # 发件人
    recipient_list = [useremail]  # 邮件接收人，为一个列表，可添加多个接收人
    send_mail(subject=subject, message=message, from_email=from_email, recipient_list=recipient_list,html_message=html_message)


#python manage.py celery worker
